package q6_threadpool_test;

import java.util.concurrent.*;

/*
你在工作中是如何创建线程池的,是否自定义过线程池使用？（考工作经验）

线程池的拒绝策略请你谈谈?
        拒绝策略是什么？
            等待队列也已经排满了,再也塞不下新的任务了
            同时,线程池的max也到达了,无法接续为新任务服务
            这时我们需要拒绝策略机制合理的处理这个问题.
        JDK内置的拒绝策略
            AbortPolicy(默认): 直接抛出RejectedException异常阻止系统正常运行
            CallerRunPolicy: "调用者运行"一种调节机制,该策略既不会抛弃任务,也不会抛出异常,而是将某些任务回退到调用者，从而降低新的任务流量
            DiscardOldestPolicy: 抛弃队列中等待最久的任务,然后把当前任务加入队列中尝试再次提交
            DiscardPolicy: 直接丢弃任务,不予任何处理也不抛出异常.如果允许任务丢失,这是最好的拒绝策略
        以上内置策略均实现了RejectExecutionHandler接口

如何合理配置线程池？你是如何考虑的？（考工作经验）
    1、CPU密集型
        CPU密集的意思是该任务需要大量的运算，而没有阻塞，CPU一直全速运行。
        CPU密集任务只有在真正的多核CPU上才可能得到加速（通过多线程）
        而在单核CPU上，无论你开几个模拟的多线程该任务都不可能得到加速，因为CPU总的运算能力就那些。
        CPU密集型任务配置尽可能少的线程数量：
        一般公式：CPU核数+1个线程的线程池
    2、IO密集型
        1）由于IO密集型任务线程并不是一直在执行任务，则应该配置尽可能多的线程，如CPU核数*2
        2）IO密集型，即该任务需要大量的IO，即大量的阻塞。
           在单线程上运行IO密集型的任务会导致大量的CPU运算能力浪费在等待。
           所以在IO密集型任务中使用多线程可以大大的加速程序运行，即使在单核CPU上，这种加速主要就是利用了被浪费掉的阻塞时间。
           IO密集型时，大部分线程都阻塞，故需要多配置线程数：
           参考公式：CPU核数 / (1 - 阻塞系数)  阻塞系数在0.8 ~ 0.9之间
           比如8核CPU：8 / (1 - 0.9) = 80个线程数
 */
public class CustomThreadPoolDemo {

    public static void main(String[] args) {
        //查看CPU核数
        System.out.println(Runtime.getRuntime().availableProcessors());

        //自定义线程池
        ExecutorService threadPool = new ThreadPoolExecutor(
                2,
                5,
                1L,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(3),
                Executors.defaultThreadFactory(),
                //new ThreadPoolExecutor.AbortPolicy()//同时间内超过8个线程就抛异常
                //new ThreadPoolExecutor.CallerRunsPolicy()//同时间内超过8个线程回退给main线程处理
                //new ThreadPoolExecutor.DiscardOldestPolicy()//抛弃队列中等待最久的任务，看执行线程数和调度，抛弃多少个不可知
                new ThreadPoolExecutor.DiscardPolicy()//同时间内超过8个线程的其他线程直接丢弃
        );
        try {
            for (int i = 1; i <= 20; i++) {
                final int tmp = i;
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName() + "\t" + tmp + " 办理业务");
                });
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            threadPool.shutdown();
        }
    }

}
